package cluster;

import redis.clients.jedis.HostAndPort;
import redis.clients.jedis.JedisCluster;

import java.io.IOException;
import java.util.HashSet;
import java.util.Set;

/**
 * @Auther: 肖冬
 * @Date: 2020/8/14 23:14
 * @Description: 集群使用 需要redis搭建集群，暂时没有，只看用法
 * 4中使用
 * 1.单机 BasicTest
 * 2.分片 ShardingTest
 * 3.哨兵 JedisSentinelTest
 * 4.集群 ClusterTest
 */
public class ClusterTest {
    public static void main(String[] args) throws IOException {
        //不管是连主备，还是连几台机器都是一样的效果
        HostAndPort hp1 = new HostAndPort("192.168.1.21", 7291);
        HostAndPort hp2 = new HostAndPort("192.168.1.21", 7292);
        HostAndPort hp3 = new HostAndPort("192.168.1.21", 7293);
        Set<HostAndPort> nodes = new HashSet<>();
        nodes.add(hp1);
        nodes.add(hp2);
        nodes.add(hp3);

        //集群使用
        JedisCluster cluster = new JedisCluster(nodes);
        cluster.set("xiaodong:cluster","xiaodong2673");
        System.out.println(cluster.get("xiaodong:cluster"));
        cluster.close();
    }
}
